google.golang.org/grpc/internal/transport.http2Client.closeStream (method)
15 uses
google.golang.org/grpc/internal/transport (current package)
http2_client.go#L888: t.closeStream(s, err, rst, rstCode, status.Convert(err), nil, false)
http2_client.go#L891: func (t *http2Client) closeStream(s *Stream, err error, rst bool, rstCode http2.ErrCode, st *status.Status, mdata map[string][]string, eosReceived bool) {
http2_client.go#L997: t.closeStream(s, err, false, http2.ErrCodeNo, st, nil, false)
http2_client.go#L1148: t.closeStream(s, io.EOF, true, http2.ErrCodeFlowControl, status.New(codes.Internal, err.Error()), nil, false)
http2_client.go#L1169: t.closeStream(s, io.EOF, false, http2.ErrCodeNo, status.New(codes.Internal, "server closed the stream without sending trailers"), nil, true)
http2_client.go#L1196: t.closeStream(s, io.EOF, false, http2.ErrCodeNo, status.Newf(statusCode, "stream terminated by RST_STREAM with error code: %v", f.ErrCode), nil, false)
http2_client.go#L1336: t.closeStream(stream, errStreamDrain, false, http2.ErrCodeNo, statusGoAway, nil, false)
http2_client.go#L1385: t.closeStream(s, st.Err(), true, http2.ErrCodeProtocol, st, nil, false)
http2_client.go#L1393: t.closeStream(s, se.Err(), true, http2.ErrCodeFrameSize, se, nil, endStream)
http2_client.go#L1433: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1456: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1500: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1506: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1561: t.closeStream(s, io.EOF, rst, http2.ErrCodeNo, statusGen, mdata, true)
http2_client.go#L1619: t.closeStream(s, status.Error(code, msg), true, http2.ErrCodeProtocol, status.New(code, msg), nil, false)